package com.xb.system.constants;

import com.xb.model.domain.Users;

import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.atomic.AtomicBoolean;

public class BatchConstants {
    //    public static final List<Users> BATCH_BUFFER_1 = Collections.synchronizedList(new ArrayList<>());
//    public static final List<Users> BATCH_BUFFER_2 = Collections.synchronizedList(new ArrayList<>());
//    public static volatile boolean USE_BUFFER_1 = true;
    public static final BlockingQueue<Users> QUEUE = new LinkedBlockingQueue<>(20000);
    public static final AtomicBoolean SIGNAL_COMPLETION = new AtomicBoolean(false);
}